/*
 * @Descripttion: 
 * @Author: xgh
 * @Date: 2022-08-31 13:03:08
 * @LastEditors: xgh
 * @LastEditTime: 2022-09-04 22:27:42
 */

var mysql = require('mysql')

var pool = mysql.createPool({
  connectionLimit:100,
  host: '127.0.0.1', // 数据库地址
  port: '3306', // 端口
  user: 'root', // 用户名称
  password: 'XGH11ZML', // 用户密码
  database: 'dataanalysis', // 要链接的数据库名称
  debug: ['ComQueryPacket'],

});

// 查询相关
let query = (sql, data,callback) => {
  pool.getConnection((err, conn) => {
    if (err) {
      callback(err, null, null);
    } else {
      conn.query(sql,data,(qerr, vals, fields) => {
        //释放连接    
        conn.release();
        //事件驱动回调    
        callback(qerr, vals, fields);
      });
    }
  })
}

module.exports = query // 暴露出这个接口